package com.wayhome.srpingbootmybatis.async.service;



import com.wayhome.srpingbootmybatis.async.dto.AsyncTaskAddDTO;
import com.wayhome.srpingbootmybatis.async.dto.AsyncTaskMessage;
import com.wayhome.srpingbootmybatis.async.dto.AsyncTaskQueryDTO;

import java.util.List;

public interface AsyncTaskService {

    /**
     * 添加一个异步任务
     * @param asyncTaskDTO
     */
    AsyncTaskMessage saveAsyncTask(AsyncTaskAddDTO asyncTaskDTO);

    /**
     * 根据taskKey查询正在执行的任务
     * @param asyncTaskQueryDTO
     * @return
     */
    int queryUserRunningTasks(AsyncTaskQueryDTO asyncTaskQueryDTO);

    Integer queryForExist(AsyncTaskQueryDTO asyncTaskQueryDTO);
}
